package com.lry.producer;

import com.lry.message.Message;
import com.lry.selector.MessageSelector;

public interface MqProducer {

    void start();

    void shutdown();

    SendResult send(Message message);

    SendResult send(Message message, MessageSelector messageSelector, Object arg);

}
